home *** CD-ROM | disk | FTP | other *** search
/ Workbench Add-On / Workbench Add-On - Volume 1.iso / BBS-Archive / Dev / GNU-SMALLTALK.lha / Delay.st < prev    next >
Text File  |  1992-02-15  |  4KB  |  167 lines
  1. "======================================================================
  2. |
  3. |   Delay Method Definitions
  4. |
  5.  ======================================================================"
  6.  
  7.  
  8. "======================================================================
  9. |
  10. | Copyright (C) 1990, 1991, 1992 Free Software Foundation, Inc.
  11. | Written by Steve Byrne.
  12. |
  13. | This file is part of GNU Smalltalk.
  14. |
  15. | GNU Smalltalk is free software; you can redistribute it and/or modify it
  16. | under the terms of the GNU General Public License as published by the Free
  17. | Software Foundation; either version 1, or (at your option) any later version.
  18. | 
  19. | GNU Smalltalk is distributed in the hope that it will be useful, but WITHOUT
  20. | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  21. | FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
  22. | details.
  23. | 
  24. | You should have received a copy of the GNU General Public License along with
  25. | GNU Smalltalk; see the file COPYING.  If not, write to the Free Software
  26. | Foundation, 675 Mass Ave, Cambridge, MA 02139, USA.  
  27. |
  28.  ======================================================================"
  29.  
  30.  
  31. "
  32. |     Change Log
  33. | ============================================================================
  34. | Author       Date       Change 
  35. | sbb         18 May 91      Actually implemented the thing.
  36. |
  37. | sbyrne     25 Apr 89      created.
  38. |
  39. "
  40.  
  41. Object subclass: #Delay
  42.        instanceVariableNames: 'resumptionTime isRelative'
  43.        classVariableNames: 'DelayQueue DelayTimeout DelayIdle'
  44.        poolDictionaries: ''
  45.        category: nil
  46. !
  47.  
  48. Delay comment: 
  49. 'I am the ultimate agent for frustration in the world.  I cause things to wait 
  50. (typically much more than is appropriate).  When a process sends one of my instances a wait message, that process goes to sleep for the interval specified 
  51. when the instance was created.'
  52. !
  53.        
  54.  
  55. !Delay class methodsFor: 'instance creation'!
  56.  
  57. forMilliseconds: millisecondCount
  58.     ^self new init: millisecondCount isRelative: true
  59. !
  60.  
  61. forSeconds: secondCount
  62.     ^self forMilliseconds: secondCount * 1000
  63. !
  64.  
  65. untilMilliseconds: millisecondCount
  66.     ^self new init: millisecondCount isRelative: false
  67. ! !
  68.  
  69.  
  70.  
  71. !Delay class methodsFor: 'general inquiries'!
  72.  
  73. millisecondClockValue
  74.     ^Time millisecondClockValue
  75. ! !
  76.  
  77.  
  78.  
  79. !Delay class methodsFor: 'initialization'!
  80.  
  81. initialize
  82.     DelayQueue _ SortedCollection sortBlock:
  83.     [ :a :b | (a key) <= (b key) ].
  84.     DelayIdle _ Semaphore forMutualExclusion.
  85.     DelayTimeout _ Semaphore new.
  86.     self startDelayLoop
  87. !
  88.  
  89. startDelayLoop
  90.     [ [ true ] whileTrue: 
  91.       [ DelayTimeout wait.
  92.         DelayIdle critical: 
  93.         [ DelayQueue removeFirst value signal.
  94.           DelayQueue isEmpty
  95.               ifFalse: [ Processor signal: DelayTimeout
  96.                        atMilliseconds: 
  97.                            (DelayQueue first key) 
  98.                      - self millisecondClockValue ]
  99.               ]
  100.         ]
  101.       ] forkAt: Processor timingPriority
  102. ! !
  103.  
  104.  
  105.  
  106. !Delay methodsFor: 'accessing'!
  107.  
  108. resumptionTime
  109.     isRelative
  110.     ifTrue: [ ^Delay millisecondClockValue + resumptionTime ] 
  111.     ifFalse: [ ^resumptionTime ] 
  112. ! !
  113.  
  114.  
  115.  
  116. !Delay methodsFor: 'process delay'!
  117.  
  118. wait
  119.     | elt sem |
  120.     DelayQueue isNil
  121.     ifTrue: [ Delay initialize ].
  122.     sem _ Semaphore new.
  123.     elt _ Association key: self resumptionTime
  124.               value: sem.
  125.     DelayIdle critical: [ DelayQueue add: elt.
  126.               "If we've become the head of the list, we need to
  127.                alter the interrupt time"
  128.               DelayQueue first == elt
  129.                   ifTrue: [ Processor signal: DelayTimeout 
  130.                           atMilliseconds: 
  131.                               (DelayQueue first key) -
  132.                                   Delay millisecondClockValue.
  133.                         ]
  134.                   ].
  135.     sem wait
  136. ! !
  137.  
  138.  
  139.  
  140. !Delay methodsFor: 'comparing'!
  141.  
  142. = aDelay
  143.     ^(isRelative = aDelay isRelative)
  144.     and: [ resumptionTime = aDelay internalResumptionTime ]
  145. !
  146.  
  147. hash
  148.     ^resumptionTime
  149. ! !
  150.  
  151.  
  152.  
  153. !Delay methodsFor: 'private'!
  154.  
  155. init: milliseconds isRelative: aBoolean
  156.     isRelative _ aBoolean.
  157.     resumptionTime _ milliseconds
  158. !
  159.  
  160. isRelative
  161.     ^isRelative
  162. !
  163.  
  164. internalResumptionTime
  165.     ^resumptionTime
  166. ! !
  167.